﻿#ifndef REDIS_ASYNC_PUB_H
#define REDIS_ASYNC_PUB_H

#include <string>

namespace pub {

    class redis_async_pub {
    public:
        redis_async_pub(const int port, const char* ip);
        ~redis_async_pub();

        void init();
        void publish(const std::string& channel, const std::string& message);

    private:
        int redis_port;
        const char* redis_ip;
        static bool is_initialized;
    };

} // namespace pub

#endif // REDIS_ASYNC_PUB_H